403Webshell
Server IP : 121.121.20.254  /  Your IP : 216.73.216.202
Web Server : Microsoft-IIS/10.0
System : Windows NT WEB-SERVER 10.0 build 20348 (Windows Server 2022) AMD64
User : IUSR ( 0)
PHP Version : 8.3.28
Disable Function : NONE
MySQL : ON  |  cURL : ON  |  WGET : OFF  |  Perl : OFF  |  Python : OFF  |  Sudo : OFF  |  Pkexec : OFF
Directory :  C:/Python315/Lib/test/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :


[ Back ]     

Current File : C:/Python315/Lib/test/__pycache__/test_queue.cpython-315.opt-2.pyc
R
>lqjɋc��]PHs]PHs]PHs]PHs]PHs]PHs]PHs]QHGsG	s	]QHG
s
]QHGs]QH0G
s
\OP	Q5\
OQQ,Q5s\
OQQ,Q	5s\O$\Q
2s]sQsQQ
\O,2sQQ2sQQ\2sQQ\2sQQ\\O62s\QQ\\O622sQQ\2sQQ\\O62s\QQ\\O622s QQ\2s!Q Q!\!\O62s"\Q"Q#\!\O622s#Q$Q%\$2s%Q&Q'\2s&Q(Q)\&\O62s'\Q*Q+\&\O622s(Q,Q-2s)Q.Q/\)\O62s*\Q0Q1\)\O622s+\,Q26Xc\OZ2P!P!)3�)�
gc_collect�
bigmemtest)�
import_helper)�threading_helper)�support)�module�queue�_queue)�blocked)�freshzNo _queue module foundc�l�UO]6�9%cUO2UO6H!�r)�maxsize�qsize��qs&�$C:\Python315\\Lib\test\test_queue.py�qfullrs'���9�9�q�=�3�3�Q�W�W�Y�!�)�)�3�3�c�.`�\sQs]snQsQsQsUsP!)�_TriggerThreadc��VmV m[O2Um[O
O
U2P!�N)�fn�args�	threading�Event�startedEvent�Thread�__init__)�selfrrs&&&rr�_TriggerThread.__init__s/�����	�%�O�O�-������!�!�$�'rc��[OQ2UOO2UOUO
P!)皙�����?)�time�sleepr�setrr�r s&r�run�_TriggerThread.run#s1��	
�
�
�3��������������r)rrr)�__name__�
__module__�__qualname__�__firstlineno__rr(�__static_attributes__�__classdictcell__��
__classdict__s@rrrs����(��rrc�.`�\sQs]<snQsQsQsUsP!)�BlockingTestMixinc�>�[V42oUO2UUUmUOO	2%fUOQU*2UO[OU2![OS2h9h)z*blocking function %r appeared not to block)r�start�resultr�is_set�failr�join_thread)r �
block_func�
block_args�trigger_func�trigger_args�threads&&&&& r�do_blocking_test�"BlockingTestMixin.do_blocking_test>sw����;������	1�$�j�1�D�K��&�&�-�-�/�/��	�	�F�$�%�&��;�;��(�(��0���(�(��0�s�+B�
#B�Bc���[V42oUO2UUUOQU*2[OU2UO
O
2%fUOQ2P!P!Scgh9h[OS2SO
O
2%fSOQ2hh9h)zexpected exception of kind %rz(trigger thread ended but event never set)rr5r8rr9rr7)r r:r;r<r=�expected_exception_classr>s&&&&&& r�do_exceptional_blocking_test�.BlockingTestMixin.do_exceptional_blocking_testLs�����;������	F�
;��J�'��	�	�9�!9�:�;�
�(�(��0��&�&�-�-�/�/��	�	�D�E�0��,�
��
��
�(�(��0��&�&�-�-�/�/��	�	�D�E�0�s(�B
�B�
B�B�B�6C �
C )r6)r*r+r,r-r?rCr.r/r0s@rr3r3<s����1�F�Frr3c�<`�\sQs]^snQsQsQsQsQsQs	Qs
QsQ	sQ
s
QsQsQ
sQsQsQsQsQsQsQsQsQsQsQsQ/QksQsQsQ/QksQs Q/Qks!Qs"Q s#Q!s$Q"s%Q#s&Q$s'Q%s(Q&s)Q's*Q(s+Q)s,Q*s-Q+s.Q,s/Q-s0Q.s1Us2P!)0�BaseQueueTestMixinc�J�]Um[O2UmP!r
)�cumr�Lock�cumlockr's&r�setUp�BaseQueueTestMixin.setUp_s����� �~�~�'��rc��UO2%c[Q2gUOUO22UO	UO22UO
]o2UO
Q2UO
]�2[,QN,QN,QNQ5oUO2UO2UO2,oUOV2UOO*Q2[[]*
2FD4oUO
U2UOUO2Q2J6	UO[U2%(Q2][*o][*oUO
U2UO[U2Q2UO	UO22UOUO22UO
U]Q5UOQ2UO
UQ	Q
5UOQ2UO%UOU1UOQ2UO%UOUP	]
1UOQ2[[2FDoUO2J	UOUO2%(Q2UO]Q5UOQ
2UOQ	Q
5UOQ2UO%UOQUOQ2UO%UOQUOQ2P!SO O"cCK}h9hSO O"cCKzh9hSO O&cK�h9hSO O&cK�h9h)�&Call this function with an empty queue�M)�Queue�	LifoQueue�
PriorityQueuez&Didn't seem to queue the correct data!�Queue should not be empty�Queue should not be full�Queue should be full��blockz(Didn't appear to block with a full queueg{�G�z�?��timeoutz+Didn't appear to time-out with a full queue�Queue should be emptyz*Didn't appear to block with an empty queuez-Didn't appear to time-out with an empty queue)�orO��)r\rOr[)r[r\rO���empty)T�
)r�RuntimeError�
assertTruer_�assertFalse�full�put�dict�get�assertEqual�	__class__r*�range�
QUEUE_SIZErr8r�Fullr?�Empty)r r�target_order�actual_order�i�lastrds&&     r�basic_queue_test�#BaseQueueTestMixin.basic_queue_testcs����7�7�9�9��G�H�H�������	�"��������"�	���c�
�	���c�
�	���c�
��O�(7�,;�=����������!�%�%�'�2������A�K�K�4H�4H�'I�A�	C��z�!�|�$�A�
�E�E�!�H��O�O�A�G�G�I�'B�C�%�	
���E�!�H��&@�A��:�~���z�!��	���d������a��"8�9��������#��������!�	�
�E�E�$�a�E� ��I�I�@�A�	�
�E�E�$��E�%��I�I�C�D�	
���a�e�e�d�W�a�e�e�R�8����a�e�e�d�D�"�%5�q�u�u�b�A��z�"�A�
�E�E�G�#����A�G�G�I�
�'>�?�	�
�E�E��E�N��I�I�B�C�	�
�E�E�$�E���I�I�E�F�	
���a�e�e�R����
�;����a�e�e�Z����
�C��5�z�z���	��	��
�z�z���	��	���z�z���	��	��
�z�z���	��	�s`�8$M;�$N�"#N?�#O �;N�N�N�N<�7N<�;N<�?O�O�O� O>�:O>�=O>c��UO2oU]6cUO2P!UO9^tt^2U9OU*
tmPPP2UO2Jr)%fhK"9h�T)rg�	task_donerJrH)r r�xs&& r�worker�BaseQueueTestMixin.worker�sO�������A��1�u����
���������A�
���
�K�K�M���s�A4�4B	�=B	c��]Um,oQFDGo[OUOU1Q5oUO	2UOU2JI	[
]d2FDoUOU2J	UO2UOUO[[
]d22Q2QFDoUOP2J	UO2SFDoUO2J	P!)r��targetrz0q.join() did not block until all tasks were done)r�)rHrrrxr5�appendrjre�joinrh�sum)r r�threadsrpr>s&&   r�queue_join_test�"BaseQueueTestMixin.queue_join_test�s���������A��%�%�T�[�[��t�D�F��L�L�N��N�N�6�"���s��A�
�E�E�!�H��	����������3�u�S�z�?�K�	M��A�
�E�E�"�I��	�����F��K�K�M�rc��UO2oUO2UOQ2P![cP!h9h�z(Did not detect task count going negative)�	type2testrvr8�
ValueError�r rs& r�test_queue_task_done�'BaseQueueTestMixin.test_queue_task_done�s@���N�N���	B�
�K�K�M�
�I�I�@�A���	��	�s�6�	A�A�Ac���UO2oUOU2UOU2UO2UOQ2P![cP!h9hr�)r�r�rvr8r�r�s& r�test_queue_join�"BaseQueueTestMixin.test_queue_join�s^��
�N�N������Q�����Q��	B�
�K�K�M�
�I�I�@�A���	��	�s�A�	A'�"A'�&A'c�v�UO[2oUOU2UOU2P!r)r�rkrrr�s& r�
test_basic�BaseQueueTestMixin.test_basic�s.��
�N�N�:�&�����a� ����a� rc�d�UO[2oUO[29^tt^2UO	]PQ5PPP2UO[29^tt^2UO]PQ5PPP2P!)%fhKK9h)%fhP!9h�r}rX)r�rk�assertRaisesr�rergr�s& r�&test_negative_timeout_raises_exception�9BaseQueueTestMixin.test_negative_timeout_raises_exception�sr���N�N�:�&��
�
�
�z�
*�
*�
�E�E�!�R�E� �+�
�
�
�z�
*�
*�
�E�E�!�R�E� �+�
*�+�
*��
*�
*�
*�s#�B�-B�B	�B	�B/	�'B/	c�8�UO[2o[[2FDoUO]2J	UO	UO
O29^tt^2UO]2PPP2[[2FDoUO2J	UO	UO
O29^tt^2UO2PPP2P!)%fhK9h)%fhP!9h)r})	r�rkrj�
put_nowaitr�rrl�
get_nowaitrm�r rrps&  r�test_nowait�BaseQueueTestMixin.test_nowait�s����N�N�:�&���z�"�A�
�L�L��O�#�
�
�
�t�z�z���
/�
/�
�L�L��O�0��z�"�A�
�L�L�N�#�
�
�
�t�z�z�/�/�
0�
0�
�L�L�N�1�
0�0�
/��
1�
0�
0�s$�,C5�D�5D	�>D	�D	�D	c�H�UO]2oUO]2UO]2UO]2UOUOO29^tt^2UO]2PPP2UO
UO2]2]UmUOUOO29^tt^2UO]2PPP2P!)%fhK�9h)%fhP!9h)�)	r�rer�rrlr�rhrrr�s& r�test_shrinking_queue�'BaseQueueTestMixin.test_shrinking_queue�s����N�N�1���	���a��	���a��	���a��
�
�
�t�z�z���
/�
/�
�L�L��O�0��������A�&���	�
�
�
�t�z�z���
/�
/�
�L�L��O�0�
/�	0�
/��0�
/�
/�s$�3C=�!D�=D
	�D
	�D!	�D!	c��UO2oUO2UOUOO29^tt^2UOQ2PPP2UOUOO29^tt^2UO
2PPP2P!)%fhKX9h)%fhP!9h��data)r��shutdownr�r�ShutDownrergr�s& r�test_shutdown_empty�&BaseQueueTestMixin.test_shutdown_empty�s����N�N���	�
�
��
�
�
�t�z�z�2�2�
3�
3�
�E�E�&�M�4�
�
�
�t�z�z�2�2�
3�
3�
�E�E�G�4�
3�4�
3��
3�
3�
3�s$�B1�C�1C	�:C	�C	�
C	c�>�UO2oUOQ2UO2UO2UO	UO
O29^tt^2UO2PPP2P!)%fhP!9hr�)r�rer�rgr�rr�r�s& r�test_shutdown_nonempty�)BaseQueueTestMixin.test_shutdown_nonempty�s^���N�N���	���f�
�	�
�
��	����
�
�
�t�z�z�2�2�
3�
3�
�E�E�G�4�
3�
3�
3�s�0B�B	�B	c�"�UO2oUOQ2UOP	Q5UOUOO
29^tt^2UO
2PPP2P!)%fhP!9h)r���	immediate)r�rer�r�rr�rgr�s& r�test_shutdown_immediate�*BaseQueueTestMixin.test_shutdown_immediatesZ���N�N���	���f�
�	�
�
�T�
�"�
�
�
�t�z�z�2�2�
3�
3�
�E�E�G�4�
3�
3�
3�s�"A=�=B	�B	c�2�UO2oUOUO2UO2UO	UO2UOP	Q5UO	UO2UOP
Q5P!)Tr�)r�rc�is_shutdownr�rbr�s& r�!test_shutdown_allowed_transitions�4BaseQueueTestMixin.test_shutdown_allowed_transitions
se���N�N���������'�	�
�
������
�
�&�	�
�
�T�
�"�����
�
�&�	�
�
�U�
�#rc�*�UO]2oUOQ2UOQ2UOU2UO	UO
O29^tt^2UOQ2PPP2UO	UO
O29^tt^2UOQ2PPP2U%c�UO	UO
O29^tt^2UO2PPP2UO	UO
O29^tt^2UO2PPP2UO	[29^tt^2UO2PPP2UO2P!UOUO2Q2UO2UOUO2Q2UO2UO2UO	UO
O29^tt^2UO2PPP2UO	UO
O29^tt^2UO2PPP2UO	UO
O29^tt^2UOP	Q2PPP2P!)%fhCKz9h)%fhCKG9h)%fhCK
9h)%fhCK�9h)%fhCK�9h)%fhCK9h)%fhK�9h)%fhP!9h)��L�O�E�W�LOg�?)
r�rer�r�r�rr�rgr�r�rvr�assertIn)r r�rs&& r�#_shutdown_all_methods_in_one_thread�6BaseQueueTestMixin._shutdown_all_methods_in_one_threads"���N�N�1���	���c�
�	���S��	�
�
�9��
�
�
�t�z�z�2�2�
3�
3�
�E�E�#�J�4�
�
�
�t�z�z�2�2�
3�
3�
�L�L���4���"�"�4�:�:�#6�#6�7�7�����8��"�"�4�:�:�#6�#6�7�7�����8��"�"�:�.�.����
�/�
�F�F�H��M�M�!�%�%�'�4�(�
�K�K�M��M�M�!�%�%�'�4�(�
�K�K�M�
�F�F�H��"�"�4�:�:�#6�#6�7�7�����8��"�"�4�:�:�#6�#6�7�7�����8��"�"�4�:�:�#6�#6�7�7����d�C� �8�7�14�
3�
3��
3�
3�
3��8�7�7��7�7�7��.�.�.��8�7�7��7�7��7�7�7�s��3K6�:L
�	L�L2�M�
M�M.�N�6L	�?L	�
L	�L	�L/	�'L/	�2M	�;M	�M	�M	�M+	�#M+	�.M>	�7M>	�N	�
N	c�&�UOP
2!�F�r�r's&r�'test_shutdown_all_methods_in_one_thread�:BaseQueueTestMixin.test_shutdown_all_methods_in_one_thread;s���7�7��>�>rc�&�UOP	2!rur�r's&r�1test_shutdown_immediate_all_methods_in_one_thread�DBaseQueueTestMixin.test_shutdown_immediate_all_methods_in_one_thread>s���7�7��=�=rc���[]U]*2FDoUOUQ12J	UO2[U]*U2FDXoUOUQ12Vt6XfJUO
2%cJ7UO2UOP	2JZ	P!SOOcSOP
2P!h9h)r�LOYD�YDLO)rjre�waitrr�r~r7r&)r r�n�results�i_when_exec_shutdown�event_shutdown�
barrier_startrps&&&&&&& r�_write_msg_thread�$BaseQueueTestMixin._write_msg_threadAs���
�q�.��1�2�A�
�E�E�1�f�+��3�	�����+�Q�.��2�A�
����q�&�k�"��(�%�,�,�.�.�"�&�&�(��N�N�4�(�3���:�:�&�&�
����u�%��
�s�B2�2C$�C$�#C$c�P�UOP	2UO2UO2UOP
2UO2J%SOOcSOP	2P!SOOcJqh9hru)rgrvr�rr�r~rm)r rr�r�s&&&&r�_read_msg_thread�#BaseQueueTestMixin._read_msg_threadYs{��	���d��	���
������
����e�����
���:�:�&�&�
����t�$���:�:�#�#�
��
�s#�!A�B%�2B%�B%� B%�$B%c��UO2UOU2UOUO2]6H2P!r
)r�r�r~r)r rr��	event_endr�s&&&&&r�_shutdown_thread�#BaseQueueTestMixin._shutdown_threadis.������	�
�
�9�����q�w�w�y�A�~�&rc�H�UO2UO2P!r)r�r)r rr�s&&&r�_join_thread�BaseQueueTestMixin._join_threadns������	���rc�v�UO2o,o,o,o,o]o]o]o	Qo
V�*oU]*oVx*o
U%c	V�*
o
[OU
2o[O2oUOVrV�V�U11UO
V�V^11UO]V&V�11,oU%c UOUOV�U112SFDXvooo[U2FDAoUO[OUUQ52UP*O2JC	JZ	SFDoUO2J	UOP	U72UOUOP	2U2U%c5UO!UP	,2UOUO#22P!P!)�r{i)r�r�Barrierrr�r�r�r~r�rjrr5rrbrh�count�assertListEqualr_)r r�r�ps�res_puts�res_gets�res_shutdown�
write_threads�read_threads�join_threads�nb_msgs�	nb_msgs_w�when_exec_shutdown�npartiesr��ev_exec_shutdown�lprocs�funcr�rrpr>s&&                    r�%_shutdown_all_methods_in_many_threads�8BaseQueueTestMixin._shutdown_all_methods_in_many_threadsss���
�N�N���
���������
��������,�	�&�!�^��!�/����$�H�!�)�)�(�3�
�$�?�?�,��
�
#�
#�]�	�,>�,9�5;�
<��
"�
"�L�h�2N�O�
�
"�
"�A��9I�'U�V�����M�M�4�,�,�l�
�<N�O�P�#�M�D�!�T��1�X���	�	�)�*�*�$�T�B�C��2������$��F��K�K�M��	
�����(�)��������-�|�<��� � ���v�6��O�O�A�G�G�I�&�rc�&�UOP
2!r��r�r's&r�)test_shutdown_all_methods_in_many_threads�<BaseQueueTestMixin.test_shutdown_all_methods_in_many_threads�s���9�9�%�@�@rc�&�UOP	2!rur�r's&r�3test_shutdown_immediate_all_methods_in_many_threads�FBaseQueueTestMixin.test_shutdown_immediate_all_methods_in_many_threads�s���9�9�$�?�?rc���UO2UO2oUOU%(2U%(!SOOcSOS2St!h9hr)r�rgr~rr�)r r�gor�r��msgs&&&&& r�_get�BaseQueueTestMixin._get�s[��
���	�	��%�%�'�C��N�N�x�<�(��<����z�z�"�"�	��N�N�8�$��O�	�s�,A�A1�A1�0A1c�*�UOVUP	2!ru)r�)r rr�r�s&&&&r�
_get_shutdown� BaseQueueTestMixin._get_shutdown�s���y�y����.�.rc���UO2UO2oUO2UOP	2U!SOO
cSOP
2P
!h9hru)r�rgrvr~rr�)r rr�r�r�s&&&& r�_get_task_done�!BaseQueueTestMixin._get_task_done�s]��
���	�	��%�%�'�C�
�K�K�M��N�N�4� ��J���z�z�"�"�	��N�N�5�!��	�s�2A�A6� A6�5A6c���UO2UOU2UOU%(2U%(!SOOcSOS2St!h9hr)r�rer~rr�)r rr�r�r�r�s&&&&&&r�_put�BaseQueueTestMixin._put�s[��
���	�	�
�E�E�#�J��N�N�x�<�(��<����z�z�"�"�	��N�N�8�$��O�	�s�-A�A2�A2�1A2c�*�UOVV4P	2!ru)r)r rr�r�r�s&&&&&r�
_put_shutdown� BaseQueueTestMixin._put_shutdown�s���y�y���d�3�3rc���UO2UOU%(2U%(!SOOcSOS2St!h9hr)rr~rr�)r rr�r�s&&&&r�_join�BaseQueueTestMixin._join�sP��	�
�F�F�H��N�N�x�<�(��<����z�z�"�"�	��N�N�8�$��O�	�s�,0�A!�
A!� A!c�(�UOVP	2!ru)r)r rr�s&&&r�_join_shutdown�!BaseQueueTestMixin._join_shutdown�s���z�z�!�d�+�+rc	�
�UO]2o,o[O2oUOQ2UOQ2U%c"UOV$U11UOV$U111oL/UO
V$U11UO
V$U11UO
V$U111o,oSFDBvqxUO
[OVxQ52UP*O2JD	UOU2UO2SFDo	U	O2J	U%cUOUP	P	,2P!UO[U2P
,P	,[U2]*
**2P!�r��Y�Dr{)r�rrrer�r�r~rr5r�r&rr��sorted�len�
r r�rr�r��thrdsr�r��params�ts
&&        r�
_shutdown_get� BaseQueueTestMixin._shutdown_get�sJ���N�N�1�����
�_�_�
��	���c�
�	���c�
���#�#�a�W�%5�6��#�#�a�W�%5�6��E����Q�G�,�-����Q�G�,�-����Q�G�,�-��E���!�L�D��N�N�9�+�+�4�E�F��B�K����"�	
�
�
�9��
�����A�
�F�F�H���� � ��4��,�7�� � ����5�'�T�F�C��J�q�L�<Q�2Q�Rrc�&�UOP
2!r��rr's&r�test_shutdown_get�$BaseQueueTestMixin.test_shutdown_get�����!�!�%�(�(rc�&�UOP	2!rurr's&r�test_shutdown_immediate_get�.BaseQueueTestMixin.test_shutdown_immediate_get�����!�!�$�'�'rc	�0�UO]2o,o[O2oUOQ2UOQ2UOUQVC11UOUQVC111o,oSFDBvqxUO[OVxQ52UP*O2JD	UO2UO2SFDo	U	O2J	UOUP	,[U2*2P!)r�rrr�r�r{)
r�rrrerr~rr5r�r&rrhrrs
&&        r�
_shutdown_put� BaseQueueTestMixin._shutdown_puts����N�N�1�����
�_�_�
��	���c�
�	���c�
��
�
�!�S�"�!6�7�
�
�
�!�S�"�!6�7�
����!�L�D��N�N�9�+�+�4�E�F��B�K����"�	
�
�
��
�����A�
�F�F�H��	
����4�&��U��"3�4rc�&�UOP
2!r��r#r's&r�test_shutdown_put�$BaseQueueTestMixin.test_shutdown_putrrc�&�UOP	2!rur&r's&r�test_shutdown_immediate_put�.BaseQueueTestMixin.test_shutdown_immediate_putr!rc
���UO2o,oUOQ2[O2oUO	2oUO
V#11UO
V#111o,oSFDBvq�UO
[OV�Q52UP*O2JD	U%f`,o
[U2FDMoUO
[OUOV$U
1Q52UP*O2JO	UOU2UO2SFDoUO2J	UOUP	,[U2*2P!)rr{)r�rerrrrr~rr5rjr�r�r&rrhr)
r r�rr�r��nbrr�r�r�resrprs
&&           r�_shutdown_join�!BaseQueueTestMixin._shutdown_joins)���N�N�����	���c�
�
�_�_�
��
�W�W�Y���Z�Z�!��&�
�Z�Z�!��&�
����!�L�D��N�N�9�+�+�4�E�F��B�K����"���C��2�Y�����y�/�/�t�7J�7J�RS�Y\�Q]�^�_����!�!�#��	
�
�
�9��
�����A�
�F�F�H��	
����4�&��U��"3�4rc�&�UOP	2!ru�r/r's&r�test_shutdown_immediate_join�/BaseQueueTestMixin.test_shutdown_immediate_join:s���"�"�4�(�(rc�&�UOP
2!r�r2r's&r�test_shutdown_join�%BaseQueueTestMixin.test_shutdown_join=s���"�"�5�)�)rc	�l�UO]2o,o[O2oUOQ2UOUQVC11UO
V#111o,oSFDBvqxUO
[OVxQ52UP*O2JD	UOUO]2UOU2UO2U%cHUOUOO29^tt^2UO!2PPP2L2UO#2o	UOU	Q2UO%2SFDo
U
O'2J	UOUP	,[)U2*2P!)%fhKO9h)r�rr�r{)r�rrrerrr~rr5rh�unfinished_tasksr�r&r�rr�r�rgrvrr)r r�rr�r�rr�r�rr6rs&&         r�_shutdown_put_join�%BaseQueueTestMixin._shutdown_put_join@sM���N�N�1�����
�_�_�
��	���c�
��
�
�!�S�"�!6�7�
�Z�Z�!��&�
����!�L�D��N�N�9�+�+�4�E�F��B�K����"�	
����+�+�Q�/�	�
�
�9��
������"�"�4�:�:�#6�#6�7�7�����8�7��U�U�W�F����V�S�)�
�K�K�M��A�
�F�F�H��	
����4�&��U��"3�4�8�7�s�F#�#F3	�,F3	c�&�UOP	2!ru�r:r's&r� test_shutdown_immediate_put_join�3BaseQueueTestMixin.test_shutdown_immediate_put_joinas���&�&�t�,�,rc�&�UOP
2!r�r=r's&r�test_shutdown_put_join�)BaseQueueTestMixin.test_shutdown_put_joinds���&�&�u�-�-rc	��UO]2o,o[O2oUOQ2UOQ2UO	UO
UO
22UOVU11UOVU11UOV11UOV111o,oSFDBvqgUO[OVgQ52UP*O2JD	UO2UOP
2SFDoUO2J	UO	UP	,[U2*2P!r)r�rrrerhr9rr�rr~rr5r&r�rr)	r rr�r�rr�r�rrs	&        r� test_shutdown_get_task_done_join�3BaseQueueTestMixin.test_shutdown_get_task_done_joings���N�N�1�����
�_�_�
��	���c�
�	���c�
�����+�+�Q�W�W�Y�7��
 �
 �1�'�"2�3�
�
 �
 �1�'�"2�3�
�Z�Z�!��&�
�Z�Z�!��&�	
����!�L�D��N�N�9�+�+�4�E�F��B�K����"�	����	�
�
�5���A�
�F�F�H��	
����4�&��U��"3�4rc�``�UU1QkoUO2n,n[OUQ5oUO2RO	P
Q5UOQQ5UO
UO22UO[R2]2UOR]*UOO2P!)c�:�RORO22P![coROS2Po=P!Po=hh9hr)r~rg�	Exception)�err�s ��rrg�9BaseQueueTestMixin.test_shutdown_pending_get.<locals>.get�s9���
"����q�u�u�w�'���
"����q�!�!��
"�s�%�	A�A�A�A)r|r�g$@rX)
r�rrr5r�rrc�is_aliverhr�assertIsInstancerr�)r rg�
get_threadrr�s&  @@r�test_shutdown_pending_get�,BaseQueueTestMixin.test_shutdown_pending_get�s����	"�
�N�N������%�%�S�1�
�����	�
�
�U�
�#������%�����,�,�.�/�����W��q�)����g�a�j�$�*�*�*=�*=�>r)rHrJr�)3r*r+r,r-rKrrrxr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�rrrrrrrr#r'r*r/r3r6r:r>rArDrNr.r/r0s@rrFrF^s�����(�6D�r��$B�B�!�!�
�����$�!�B?�>�)�0� '�
�
.'�`A�@��/�	��4��,� S�D)�(�5�.)�(�5�6)�*�5�B-�.�5�2?�?rrFc�4``�\sQsQsnU1QksQsUsU9s!)�	QueueTest�c�\:�UOOUm[RU_2P!r)rrPr��superrK�r ris&�rrK�QueueTest.setUp�s������)�)���
��
�r�r��r*r+r,r-rKr.r/�
__classcell__�rir1s@@rrQrQ�������rrQc��\sQsQs\sQsP!)�PyQueueTest�r]�r*r+r,r-�py_queuerr.r]rrr]r]�����Err]c��\sQsQs\sQsP!)�
CQueueTest�r]�r*r+r,r-�c_queuerr.r]rrrcrc�����Errcc�4``�\sQsQsnU1QksQsUsU9s!)�
LifoQueueTest�c�\:�UOOUm[RU_2P!r)rrQr�rTrKrUs&�rrK�LifoQueueTest.setUp�s������-�-���
��
�rrWrXrZs@@rriri�r[rric��\sQsQs\sQsP!)�PyLifoQueueTest�r]r_r]rrrnrn�rarrnc��\sQsQs\sQsP!)�CLifoQueueTest�r]rer]rrrqrq�rgrrqc�4``�\sQsQsnU1QksQsUsU9s!)�PriorityQueueTest�c�\:�UOOUm[RU_2P!r)rrRr�rTrKrUs&�rrK�PriorityQueueTest.setUp�s������1�1���
��
�rrWrXrZs@@rrtrt�r[rrtc��\sQsQs\sQsP!)�PyPriorityQueueTest�r]r_r]rrryry�rarryc��\sQsQs\sQsP!)�CPriorityQueueTest�r]rer]rrr|r|�rgrr|c��\sQsQsQsP!)�FailingQueueException��r]�r*r+r,r-r.r]rrrr�s��rrc�@``�\sQsQsnU1QksQsQsQsUsU9s	!)�FailingQueueTest��c�|:`�UOOnU1QkQR2oVm[RU_2P!)c�H:`�\sQsQsnU1QksU1QksU1QksQsUsP!)�,FailingQueueTest.setUp.<locals>.FailingQueue��c�P:�P
UmP
UmROU,UN3P!r�)�
fail_next_put�
fail_next_getr)r rrPs&*�rr�5FailingQueueTest.setUp.<locals>.FailingQueue.__init__�s$���%*��"�%*��"����t�+�d�+rc�p:�UO%cP
Um[Q2gROV2!�FzYou Lose)r�rr)r �itemrPs&&�rr�1FailingQueueTest.setUp.<locals>.FailingQueue._put�s1����%�%�%�).�D�&�/�
�;�;��z�z�$�-�-rc�p:�UO%cP
Um[Q2gROU2!r�)r�rr�)r rPs&�rr��1FailingQueueTest.setUp.<locals>.FailingQueue._get�s1����%�%�%�).�D�&�/�
�;�;��z�z�$�'�'r)r�r�)	r*r+r,r-rrr�r.r/)r1rPs@�r�FailingQueuer��s����
,�
.�

(�
(rr�)rrPr�rTrK)r r�rPris& @�rrK�FailingQueueTest.setUp�s/����
�
� � ��	(�5�	(� )��
��
�rc��UO2%c[Q2g[[]*
2FDoUO	U2J	P	UmUO	Q]Q5UO
Q2P	UmUO	QQQ5UO
Q2UO	Q2UO[U2Q2P	UmUOUOQUOQ
2UO
Q2UO	Q2P	UmUOUOQUOQ
[2UO
Q2UO	Q2UO[U2Q2UO2UO[U2%(Q2UO	Q2UO[U2Q2UOUOQUOQ
2[[2FDoUO2J	UOUO2%(Q	2UO	Q
2P	Um
UO2UO
Q2UOUO2Q2P	Um
UOQQ5UO
Q2UOUO2Q2UO2UOUO2%(Q	2P	Um
UOUOQ
UOQ[2UO
Q2UOUO2Q2UO2UOUO2%(Q	2P![cCKqh9h[cCKWh9h[cCK�h9h[cCK�h9h[cCK�h9h[cCKZh9h[cK�h9h)rN�oopsrVz)The queue didn't fail when it should haver#rXrqrUrTrZ�firstrS)rdr])rdTr`r^)rrarjrkrer�r8rrbrr?rgrCr�r�s&& r�failing_queue_test�#FailingQueueTest.failing_queue_test�sn���7�7�9�9��G�H�H��z�!�|�$�A�
�E�E�!�H�%����	�
�E�E�&��E�"��I�I�A�B����	�
�E�E�&�#�E�&��I�I�A�B�	
���f�
�����a��"8�9����	��!�!�!�%�%��A�E�E�2�>��I�I�A�B�
	
���f�
����	��-�-�a�e�e�5G����PR�.C�
E��I�I�A�B�
	
���f�
�����a��"8�9�	�������E�!�H��&@�A�	���f�
�����a��"8�9����a�e�e�Y����r�:��z�"�A�
�E�E�G�#����A�G�G�I�
�'>�?�	���g�����	�
�E�E�G��I�I�A�B�	
������	�#>�?����	�
�E�E�#�E���I�I�A�B�	
������	�#>�?�	�������A�G�G�I�
�'>�?����	��-�-�a�e�e�R����
�.C�
E��I�I�A�B�	
������	�#>�?�	�������A�G�G�I�
�'>�?��K%�	��	��%�	��	��%�	��	��%�	��	��*%�	��	��%�	��	��%�	��	�s��$O!�$O3�9P�0>P�!P)�#P;�>Q
�!	O0�+O0�/O0�3	P�=P�P�	P�P�P�	P&�!P&�%P&�)	P8�3P8�7P8�;	Q
�Q
�	Q
�
	Q�Q�Qc�v�UO[2oUOU2UOU2P!r)r�rkr�r�s& r�test_failing_queue�#FailingQueueTest.test_failing_queue0s0��
���j�)������"�����"r)r�)
r*r+r,r-rKr�r�r.r/rYrZs@@rr�r��s�����0O@�b#�#rr�c��\sQsQs\sQsP!)�PyFailingQueueTest�:r]r_r]rrr�r�:rarr�c��\sQsQs\sQsP!)�CFailingQueueTest�>r]rer]rrr�r�>rgrr�c��`�\sQsQsnQsQsQsQsQsQs	Qs
Q	sQ
s\
]2QP
Q5Q2s\
]2QP
Q5Q
2s\
]2QP
Q5Q2sQsQsUsP!)�BaseSimpleQueueTest�Cc�2�UO2UmP!r)r�rr's&rrK�BaseSimpleQueueTest.setUpEs�����!��rc��UO2oUOU2UO2Q6�fJ:[O
UO2Q*2Jg[cSOS2P!h9h)Tg�?���MbP?)�pop�
IndexErrorre�randomr$r%)r r�seq�rnd�sentinel�vals&&&&& r�feed�BaseSimpleQueueTest.feedHsf���
��g�g�i��
�E�E�#�J��z�z�|�c�!��
�
�3�:�:�<�$�.�/���
����h���
�s�A)�)	B	�3B	�B	c�\�UO2oVC6XcP!UOU2J,ru)rgr~�r rr�r�r�s&&&& r�consume�BaseSimpleQueueTest.consumeSs$����%�%�'�C�����N�N�3�rc���UOP
Q5oVC6XcP!UOU2J1SOOc[OQ2Jdh9h)TrV��h㈵��>)rgrrmr$r%r~r�s&&&& r�consume_nonblock�$BaseSimpleQueueTest.consume_nonblockZs]������%�%�e�%�,�C������N�N�3���
�z�z�'�'�%��J�J�t�$�%�s�3�A(�
A(�'A(c��UOQQ5oVC6XcP!UOU2J1SOOcJNh9h)Tr�rX)rgrrmr~r�s&&&& r�consume_timeout�#BaseSimpleQueueTest.consume_timeoutgsT������%�%��%�-�C������N�N�3���
�z�z�'�'����s�3�A�
A�Ac�`�,oPoUO2oUO2[O]*2o	,nU1Qko
[	U2Tt,tFD#o[
OU
U2V(V�1Q5MJ%	oo[	U2Tt,tFD#o[
OU
U2V&U1Q5MJ%	o
o[OV�*29^tt^2PPP2UOR2UOUO22UOUO2]2U!ttohttoh)%fhKl9h)Nc�:`�UU1QkoU!)c�r:�RU-U@P![coROS2Po=P!Po=hh9hr)�
BaseExceptionr~)r�kwargsrI�
exceptions�fs*, ��r�wrapper�HBaseSimpleQueueTest.run_threads.<locals>.log_exceptions.<locals>.wrapper}s6���)��t�&�v�&��$�)��%�%�a�(�(��)�s�	�	6�6�1�6r])r�r�r�sf �r�log_exceptions�7BaseSimpleQueueTest.run_threads.<locals>.log_exceptions|s���
)�
�Nrr{)�copy�reverser��Randomrjrrr�
start_threadsrcrbr_rhr)r �	n_threadsr�inputs�	feed_func�consume_funcr�r�r�r�r�rp�feeders�	consumersr�s&&&&&&        @r�run_threads�BaseSimpleQueueTest.run_threadsts-��������k�k�m�����
��m�m�B����
�	�"�)�,�.�,�q��#�#�>�)�+D�*+�#�)@�B�,�	�.�
$�I�.�0�.���%�%�^�L�-I�,-��+A�C�.�	�0��
+�
+�G�,?�
@�
@��A�	
����$�������	�"��������A�&����.��0�A�
@�s�+D7�
+D<�E�E	�
E	c�B�UOoUOUO22UOUO	2]2UO]2UO
UO22UOUO	2]2UO]2UO]2UO]2UO
UO22UOUO	2]2UOUO2]2UOUO	2]2UOUO2]2UOUO	2]2UOUOP
Q5]2UO
UO22UOUO	2]2UOUOQQ5]2UOUO22UOUO	2]2UOUOO29^tt^2UOP
Q5PPP2UOUOO29^tt^2UOQQ5PPP2UOUOO29^tt^2UO2PPP2UOUO22UOUO	2]2P!)%fhK�9h)%fhK�9h)%fhKw9h)rrVr#rXr�)
rrbr_rhrrercr�rgr�r�rrmr�s& rr��BaseSimpleQueueTest.test_basic�sW���F�F��������	�"��������A�&�	���a���������#��������A�&�	���a��	���Q��	���a���������#��������A�&��������!�$��������A�&���������+��������A�&�������U��+�Q�/��������#��������A�&�������s��+�Q�/�������	�"��������A�&�
�
�
�t�z�z�/�/�
0�
0�
�E�E��E��1�
�
�
�t�z�z�/�/�
0�
0�
�E�E�$�E��1�
�
�
�t�z�z�/�/�
0�
0�
�L�L�N�1�������	�"��������A�&�1�
0��
0�
0��
0�
0�s6�>M(�M;�N�(M8	�1M8	�;N	�N	�N	�N	c���UOoUO]2UO[29^tt^2UO	PQ5PPP2P!)%fhP!9hr�)rrer�r�rgr�s& rr��:BaseSimpleQueueTest.test_negative_timeout_raises_exception�sD���F�F��	���a��
�
�
�z�
*�
*�
�E�E�"�E��+�
*�
*�
*�s�A�A*	�"A*	c��UOo[[]d22oUO]VUOUO
2oUO
V22P!)�d)r�listrjr�r�r�rh)r rr�r�s&   r�
test_order�BaseSimpleQueueTest.test_order�sG���F�F���e�C�j�!���"�"�1�a����D�L�L�I��	
����)r)�size�memuse�dry_runc���UOo[[Q22oUOVV0OUO
2oUO
[U2U2P!��')rr�rjr�r�r�rhr�r r�rr�r�s&&   r�test_many_threads�%BaseSimpleQueueTest.test_many_threads�sM��
�F�F���e�E�l�#���"�"�4�F�I�I�t�|�|�L��	
������&�1rc���UOo[[Q22oUOVUUOUO
2oUO
[U2U2P!r�)rr�rjr�r�r�rhrr�s&&   r�test_many_threads_nonblock�.BaseSimpleQueueTest.test_many_threads_nonblock�sU��
�F�F���e�E�l�#���"�"�4�F�#'�9�9�d�.C�.C�E��	
������&�1rc���UOo[[Q22oUOVUUOUO
2oUO
[U2U2P!)��)rr�rjr�r�r�rhrr�s&&   r�test_many_threads_timeout�-BaseSimpleQueueTest.test_many_threads_timeout�sU��
�F�F���e�D�k�"���"�"�4�F�#'�9�9�d�.B�.B�D��	
������&�1rc�8�QQ2o]oUOo[U2FDoUOU22J	[U2FDGo[OUO22o[
2UOU22JI	P!)c��\sQsQsQsP!)�.BaseSimpleQueueTest.test_references.<locals>.C��r]r�r]rr�Cr��s��rr�)rrjre�weakref�refrgr�assertIsNone)r r��Nrrp�wrs&     r�test_references�#BaseSimpleQueueTest.test_references�sn��	�	�
���F�F���q��A�
�E�E�!�#�J���q��A����Q�U�U�W�%�B��L����b�d�#�rri@)r*r+r,r-rKr�r�r�r�r�r�r�r�rr�r�r�r�r.r/r0s@rr�r�Cs�����"�	0� � � ��@#'�J�*��R�	�5�9�2�:�2��R�	�5�9�2�:�2��R�	�5�9�2�:�2�
$�
$rr�c�8``�\sQsQsn\sU1QksQsUsU9s	!)�PySimpleQueueTest�c�\:�UOOUm[RU_2P!r)r�_PySimpleQueuer�rTrKrUs&�rrK�PySimpleQueueTest.setUp�s������2�2���
��
�rrW)
r*r+r,r-r`rrKr.r/rYrZs@@rr�r��s�����E��rr�c�J``�\sQsQsn\sU1QksQsQsQs	Qs
UsU9s!)�CSimpleQueueTest�c�\:�UOOUm[RU_2P!r)r�SimpleQueuer�rTrKrUs&�rrK�CSimpleQueueTest.setUps������/�/���
��
�rc���UOUOUOO2UOUOUOO2P!r)�assertIsr�rrr's&r�test_is_default� CSimpleQueueTest.test_is_defaults:���
�
�d�n�n�d�j�j�&<�&<�=��
�
�d�n�n�d�j�j�&<�&<�=rc�t�UO2o[OQ2o[OVU[O
Q2*2[
Q2FDoUO[22J	[OVU[O
Q2*2P!)z?nnPnnPr��PPPPPPPP�PPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPPP)	r�r�calcobjsize�check_sizeof�struct�calcsizerjre�object)r r�basesize�_s&   r�test_simplequeue_sizeof�(CSimpleQueueTest.test_simplequeue_sizeofsu���N�N����&�&�y�1�����T�h�����1I�&I�J��t��A�
�E�E�&�(�O�����T�h�����1L�&L�Mrc	�x``�UOn[O2nQo,oUU1QkQ[2oU2oRO	[R22=UO
RO22UP*U6�fJRUOU[[U]*222P!)r�c�8:`�\sQsQsnQsUU1QksQsUsP!)�2CSimpleQueueTest.test_reentrancy.<locals>.Circularic��VmP!r��circularr's&rr�;CSimpleQueueTest.test_reentrancy.<locals>.Circular.__init__ s�� $�
rc�>:�RO[R22P!r)re�next)r �genrs&��r�__del__�:CSimpleQueueTest.test_reentrancy.<locals>.Circular.__del__#s������d�3�i� rr)r*r+r,r-rr r.r/)r1rrs@��r�Circularrs����
%�
!�
!rr")r�	itertoolsr�rrerr~rgrhr�rj)r r�r�r"�orrs&    @@r�test_reentrancy� CSimpleQueueTest.test_reentrancys����
�F�F���o�o�������
	!�	!�v�	!���
�A�
�E�E�$�s�)����N�N�1�5�5�7�#��r�{�a�������$�u�Q��U�|�"4�5rrW)
r*r+r,r-rfrrKrrr%r.r/rYrZs@@rrr�s&����
�E��>�N�6�6rr�__main__).r#r�rrr$�unittestr��test.supportrrrr�testr�requires_working_threading�import_fresh_moduler`rf�
skipUnless�need_c_queuerkrrrr3rFrQ�TestCaser]rcrirnrqrtryr|rHrr�r�r�r�r�rr*�mainr]rr�<module>r1s-���
�
�����/�&�)���+�+�4�8��,�,�W�x�j�I��
�
+�
+�G�H�:�
F���"�"�7�,D�E��
�
�4��Y�%�%��@F�F�Dq?�*�q?�h�"���)�X�.�.�����H�-�-�����&���m�X�%6�%6����]�H�$5�$5�����*���+�X�->�->����*�H�,=�,=����
-�I�,�q#�(�q#�j�)�8�+<�+<����(�(�*;�*;����q$�q$�h�+�X�->�->���.6�*�H�,=�,=�.6��.6�b�z���M�M�O�r

Youez - 2016 - github.com/yon3zu
LinuXploit